package com.ljf.framework.util;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

/**
 * 说明：
 *
 * @Auther: lijinfeng
 * @Date: 2024/5/21
 */
public class LjfHttpUtil {
    /**
     * 发送get请求
     *
     * @param urlString 请求路径
     * @param param     请求参数
     */
    public static String doGet(String urlString, Map param) {
        String msg = "";
        try {
            // 1. 得到访问地址的URL "http://localhost:8080/Servlet/do_login.do?username=test&password=123456"
            StringBuilder newUrl = new StringBuilder();
            newUrl.append(urlString).append("?");
            param.forEach((k,v)->{
                newUrl.append(k).append("=").append(v).append("&");
            });
            newUrl.delete(newUrl.length()-1,newUrl.length());
            URL url = new URL(newUrl.toString());
            // 2. 得到网络访问对象java.net.HttpURLConnection
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            /* 3. 设置请求参数（过期时间，输入、输出流、访问方式），以流的形式进行连接 */
            // 设置是否向HttpURLConnection输出
            connection.setDoOutput(false);
            // 设置是否从HttpUrlConnection读入
            connection.setDoInput(true);
            // 设置请求方式
            connection.setRequestMethod("GET");
            // 设置是否使用缓存
            connection.setUseCaches(true);
            // 设置此 HttpURLConnection 实例是否应该自动执行 HTTP 重定向
            connection.setInstanceFollowRedirects(true);
            // 设置超时时间
            connection.setConnectTimeout(3000);
            // 连接
            connection.connect();
            // 4. 得到响应状态码的返回值 responseCode
            int code = connection.getResponseCode();
            // 5. 如果返回值正常，数据在网络中是以流的形式得到服务端返回的数据
            msg = "";
            if (code == 200) { // 正常响应
                // 从流中读取响应信息
                BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
                String line = null;
                while ((line = reader.readLine()) != null) { // 循环从流中读取
                    msg += line + "\n";
                }
                reader.close(); // 关闭流
            }
            // 6. 断开连接，释放资源
            connection.disconnect();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return msg;

    }

    /**
     * 发送post请求
     *
     * @param urlString
     * @param param
     * @return
     */
    public static String doPost(String urlString, Map param) {
        // 从连接中读取响应信息
        String msg = "";
        try {
            // 1. 获取访问地址URL
            URL url = new URL(urlString);
            // 2. 创建HttpURLConnection对象
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            /* 3. 设置请求参数等 */
            // 请求方式
            connection.setRequestMethod("POST");
            // 设置连接超时时间
            connection.setConnectTimeout(3000);
            // 设置是否向 HttpUrlConnection 输出，对于post请求，参数要放在 http 正文内，因此需要设为true，默认为false。
            connection.setDoOutput(true);
            // 设置是否从 HttpUrlConnection读入，默认为true
            connection.setDoInput(true);
            // 设置是否使用缓存
            connection.setUseCaches(false);
            // 设置此 HttpURLConnection 实例是否应该自动执行 HTTP 重定向
            connection.setInstanceFollowRedirects(true);
            // 设置使用标准编码格式编码参数的名-值对
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            // 添加 HTTP HEAD 中的一些参数。　　　　　　  // JDK8中，HttpURLConnection默认开启Keep-Alive
            // connection.setRequestProperty("Connection", "Keep-Alive");
            // 连接
            connection.connect();
            /* 4. 处理输入输出 */
            // 写入参数到请求中
            StringBuilder params = new StringBuilder();

            for (Object next : param.entrySet()) {
                params.append(next.toString()).append("&");
            }
            params = new StringBuilder(params.substring(0, params.length() - 1));

            OutputStream out = connection.getOutputStream();
            out.write(params.toString().getBytes());
            out.flush();
            out.close();
            // 5. 断开连接
            connection.disconnect();

        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return msg;
    }


    public static void main(String[] args) {
        HashMap<String, String> map = new HashMap<>();
        map.put("1", "appId");
        map.put("2", "appSc");
        Iterator<Map.Entry<String, String>> iterator = map.entrySet().iterator();

        while (iterator.hasNext()) {
            Object next = iterator.next();
            System.out.println(next.toString());
        }

        StringBuffer newUrl = new StringBuffer();
        newUrl.append("http://loacalhoat:8080/login").append("?");
        map.forEach((k,v)->{
            newUrl.append(k).append("=").append(v).append("&");
        });
        newUrl.delete(newUrl.length()-1,newUrl.length());
        System.out.println(newUrl.toString());
    }
}
